# 主程序
import os
from celery import Celery


if not os.getenv('DJANGO_SETTINGS_MODULE'):
    os.environ['DJANGO_SETTINGS_MODULE'] = 'meiduo_mall.settings.dev'

app = Celery('meiduo')
# 加载配置信息
app.config_from_object('celery_tasks.config')

# 声明获取异步任务的队列【目录中必须有一个tasks.py,这个就是任务文件】
app.autodiscover_tasks(['celery_tasks.sms', 'celery_tasks.emails', 'celery_tasks.html',])

# 在终端下执行一个命令
# celery -A 主程序路径 worker -l info
# 在当前项目中，命令就是
# 在meiduo_mall/meiduo_mall 这个目录中运行
# celery -A celery_tasks.main worker -l info
